package iserver

import (
	"broker/interface/imodel"
	"broker/struct/model"
)

/**
 * @Description
 * @Author huan.wang
 * @Date 2021/4/26 6:44 下午
 **/

type ITopicManager interface {
	Publish(message model.PublishMessage, connection IConnection) error
	Subscribe(subscriber imodel.ISubscriber) error
	UnSubscribe(subscriber imodel.ISubscriber) error
	RemoveSubscribe(unsubscriber imodel.ISubscriber) error
}
